package gateway.api.engine;

import gateway.api.aware.DisposableAware;
import gateway.api.aware.InitializingAware;
import gateway.internal.api.message.DefaultMessage;

import java.util.concurrent.ExecutorService;

/**
 * @author Jin Zheng
 * @since 1.0 2020-09-15
 */
public interface Engine extends InitializingAware, DisposableAware
{

	void dispatch(String connectorId, DefaultMessage message);

	ExecutorService getExecutorService();

}
